// 检查队列历史记录并创建测试任务

async function checkQueueHistory() {
  console.log('🚀 检查队列历史记录并创建测试任务...');
  
  try {
    // 获取当前历史记录
    console.log('\n1. 获取当前历史记录...');
    const historyResponse = await fetch('http://localhost:3003/api/queue/history');
    
    if (historyResponse.ok) {
      const historyResult = await historyResponse.json();
      console.log(`✅ 获取到 ${historyResult.data.length} 条历史记录`);
      
      // 显示最近的几条记录
      console.log('\n📋 最近的任务记录:');
      console.log('任务ID | 任务类型 | 状态 | 耗时 | 时间');
      console.log('-------|----------|------|------|------');
      
      historyResult.data.slice(0, 5).forEach((item, index) => {
        const duration = item.duration !== undefined ? 
          (item.duration < 1000 ? `${item.duration}ms` : `${(item.duration / 1000).toFixed(2)}s`) : 
          'N/A';
          
        console.log(`${item.id.substring(0, 8)} | ${item.task?.type || '未知'} | ${item.status} | ${duration} | ${new Date(item.timestamp).toLocaleTimeString()}`);
      });
    } else {
      console.error('❌ 获取历史记录失败:', historyResponse.status);
    }
    
    // 创建一个测试任务来验证耗时显示
    console.log('\n2. 创建测试任务...');
    const testTask = {
      type: 'long-running-task',
      index: Math.floor(Math.random() * 10000),
      duration: 3 // 3秒
    };
    
    const taskResponse = await fetch('http://localhost:3003/api/queue/task', {
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
      },
      body: JSON.stringify({ task: testTask })
    });
    
    if (taskResponse.ok) {
      const taskResult = await taskResponse.json();
      console.log(`✅ 测试任务创建成功 (ID: ${taskResult.taskId})`);
      console.log('⏳ 任务将在3秒后完成，请刷新队列状态页面查看耗时信息');
    } else {
      console.error('❌ 测试任务创建失败:', taskResponse.status);
    }
    
    console.log('\n✅ 队列历史记录检查完成');
  } catch (error) {
    console.error('❌ 检查过程中发生错误:', error);
  }
}

// 运行检查
checkQueueHistory();